import sqlalchemy as saimport asynciofrom aiomysql.sa import create_engineasync def go(loop):    """    aiomysql项目地址:https：//github.com/aio-libs/aiomysql    :param loop:    :return:    """    engine = await create_engine(user="root",                                 db="mysql",                                 host="127.0.0.1",                                 password="123456",                                 loop=loop)    async with engine.acquire() as conn:        await conn.execute(user.insert().values(user_name='user_name01', pwd='123456', real_name='real_name01'))        await conn.execute("commit")    engine.close()    await engine.wait_closed()loop = asyncio.get_event_loop()loop.run_until_complete(go(loop))